package com.ff.kvm.service.impl;

import com.ff.kvm.common.vo.Response;
import com.ff.kvm.service.KfkService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.concurrent.ListenableFuture;

@Service
public class KfkServiceImpl implements KfkService {
//
//    @Autowired
//    private KafkaTemplate kafkaTemplate;
//
//    @Autowired
//    public Response<Boolean> send(){
//        String message = "test message!";
//        ListenableFuture future = kafkaTemplate.send("app", message);
//        //future.addCallback(o -> System.out.println("send-消息发送成功：" + message), throwable -> System.out.println("消息发送失败：" + message));
//        return null;
//    }



}
